package com.study.flink;

import com.study.flink.demo.ConnectionDemo;
import com.study.flink.demo.PeterDemo;
import com.study.flink.demo.TestDemo;
import com.study.flink.demo.TicketsPricingCsvDataStreamDemo;
import com.study.flink.demo.ZomatoDemo;

import lombok.extern.slf4j.Slf4j;

/**
 * Hello world!
 *
 */
@Slf4j
public class App {
    public static void main(String[] args) throws Exception {
        fun03(args);
    }
    
    public static void test() throws Exception {
        new TestDemo().run();
    }

    public static void fun00(String[] args) throws Exception {
        new ZomatoDemo().run();
    }

    public static void fun01(String[] args) throws Exception {
        // new TicketsPricingDemo().run();
        // new TicketsPricingCsvDataSetDemo().run();
        new TicketsPricingCsvDataStreamDemo().run();
    }

    public static void fun02(String[] args) {
        // new HumidityJoinTemperatureDemo().run(args);
        new ConnectionDemo().run(args);
    }

    public static void fun03(String[] args) throws Exception {
        new PeterDemo().run(args);
    }

}
